package com.gitee.ywj1352.stream.input;

import org.springframework.cloud.stream.annotation.EnableBinding;
import org.springframework.cloud.stream.annotation.StreamListener;
import org.springframework.messaging.handler.annotation.SendTo;

@EnableBinding(MyInput.class)
public class InputListener {

    @StreamListener("myInput")
    @SendTo("myAck")
    public String myListener(Object payload){
        System.out.println("中转消息。。"+payload);
        return "xxxxx";
    }
}
